# 生产者
# 需要单独创建一个任务包，任务包中的py文件必须一tasks.py作为文件名
# 生产者 / 函数本质上一个函数
# 必须经过celery的实例对象的task装饰器装饰
from apps.verifications.constant import YUNTONGXUN_EXPIRE_TIME
from libs.yuntongxun.sms import CCP
from celery_tasks.main import app
import logging
logger = logging.getLogger('django')


#函数中self就是task任务本身
@app.task(bind=True,default_retry_delay=5,name='send_sms')
def send_sms_code(self,mobile,sms_code):

   try:

      result =CCP().send_template_sms(mobile,[sms_code,YUNTONGXUN_EXPIRE_TIME],1)

      if result != 0:
         raise Exception('下班失败')


   except Exception as exc:
      logger.error(exc)

      raise  self.retry(exc=exc,max_retries=3)

#atuodiscover_tasks (列表)
#列表中的元素是任务包的路径
